package com.webflux.sample.webfluxmain;

import reactor.core.publisher.Flux;

public class _5_2operator_filter {

  public static void main(String[] args) {
    // 对流中包含的元素进行过滤，只留下满足Predicate指定条件的元素
    Flux.range(1, 10).filter(i -> i%2 == 0).subscribe(System.out::println);
  }

}
